package com.it.rabbitmqwithjiang.Service;

import com.it.rabbitmqwithjiang.Dao.MessageDao;
import org.springframework.amqp.core.Message;


public interface Publisher {
     void senddefaultdirectMessage(String queue, MessageDao messageDao);//向队列queue发送消息
     void senddirectMessage(MessageDao messageDao, String routingkey);//使用direct交换机发送消息
     void sendfanoutMessage(MessageDao messageDao);//使用fanout交换机发布消息给所有队列
     void sendtopicMessage(MessageDao messageDao, String routingkey);//使用topic交换机发送消息
     void TTLMessage(Message message);  //ttl（消息）设置过期时间
}



